网络编程网络编程TCP传输&&UDP传输[网络编程]
JayfarTCP：一种面向连接（连接导向）的，可靠的，基于字节流的运输层（Transport layer）通信协议。
TCP传输协议
TCP：一种面向连接（连接导向）的，可靠的，基于字节流的运输层（Transport layer）通信协议。
特点：
- 面向连接
- 点到点的通信
- 高可靠性
- 占用系统资源多，效率低
UDP传输协议
UDP: 一种无连接的传输层协议，提供面向事务的简单不可靠信息传送服务。
特点：
- 非面向连接，传输不可靠，可能丢失
- 发送不管对方是否准备好，接受方收到也不确认
- 可以广播发送
- 非常简单的协议，开销小
套接字Socket
- 我们开发的网络应用程序位于应用层，TCP和UDP属于传输层协议，在应用层如何使用传输层的服务呢？在应用层和传输层之间，则是使用套接字来进行分离。
UDP编程
需求：完成在线咨询功能；
分析：
- 使用基于UDP协议的Socket网络编程实现
- 不需要利用IO流实现数据的传输
- 每个数据发送单元被统一封装成数据包的方式，发送方将数据包发送到网络中，数据包在网络中去寻找他的目的地。
UDP基本概念：
- DatagramSocket: 用于发送或接受数据包的套接字
- DatagramPacket: 数据包
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
| package cn.location;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UdpServer {
public static void main(String[] args) throws IOException {
System.out.println("接受方启动中。。。");
DatagramSocket server = new DatagramSocket(5788);
byte[] container = new byte[1024*60];
DatagramPacket packet = new DatagramPacket(container, 0,container.length);
server.receive(packet);
byte[] datas = packet.getData();
int len = packet.getLength();
System.out.println(new String(datas,0,len));
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
| package cn.location;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
public class UdpClient {
public static void main(String[] args) throws IOException {
System.out.println("发送方启动中");
DatagramSocket client = new DatagramSocket(8889);
String data = "上海尚学堂";
byte[] datas = data.getBytes();
DatagramPacket packet = new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",5788));
client.send(packet);
|
1
2
3
4
5
6
7
8
9
10
11
12
| package cn.location;
public class TalkTeacher {
public static void main(String[] args) {
new Thread(new TalkReceive(9999,"学生")).start();
new Thread(new TalkSend(5555,"localhost",8888)).start(); |
1
2
3
4
5
6
7
8
9
10
11
12
| package cn.location;
public class TalkStudent {
public static void main(String[] args) {
new Thread(new TalkSend(7777,"localhost",9999)).start();
new Thread(new TalkReceive(8888,package cn.location;
public class TalkStudent {
public static void main(String[] args) {
new Thread(new TalkSend(7777,"localhost",9999)).start();
new Thread(new TalkReceive(8888,"老师")).start();
}
}
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
| package cn.location;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
public class TalkSend implements Runnable{
private DatagramSocket client;
private BufferedReader reader;
private String toIP;
private int toPort;
public TalkSend(int port,String toIP, int toPort) {
this.toIP = toIP;
this.toPort = toPort;
try {
client = new DatagramSocket(port);
reader = new BufferedReader(new InputStreamReader(System.in));
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while(true) {
String data;
try {
data = reader.readLine();
byte[] datas = data.getBytes();
DatagramPacket packet =
new DatagramPacket(datas,0,datas.length,new InetSocketAddress(this.toIP,this.toPort));
client.send(packet);
if (data.equals("bye")) {
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
| package cn.location;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class TalkReceive implements Runnable{
private DatagramSocket server;
private String from;
public TalkReceive(int port,String from) {
this.from = from;
try {
server = new DatagramSocket(port);
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while(true) {
byte[] container = new byte[1024*60];
DatagramPacket packet = new DatagramPacket(container, 0,container.length);
try {
server.receive(packet);
byte[] datas = packet.getData();
int len = packet.getLength();
String data = new String(datas,0,len);
System.out.println(from + ":" + data);
if (data.equals("bye")) {
break;
}
} catch (IOException e) {
|
TCP编程
需求：完成网络登录功能
- 用户输入用户名密码，服务器给出登录成功或失败的提示
分析：
- 使用基于TCP协议的Socket网络编程实现
- TCP协议基于请求-响应模式
- 在网络通讯中，第一次主动发起通讯的程序被称为客户端程序
- 第一次通讯中等待连接的程序被称作服务器端（Server）程序
- 利用IO流实现数据的传输
网络登录功能分解：
- 单向：客户端向服务器端发送字符串，服务器获取字符串并输出
- 双向：服务器端给出客户端反馈，客户端得到反馈并输出
- 文件：客户端向服务器端上传文件，服务器端获取文件并反馈结果
- 多线程：服务器接受多个客户端的请求，并给出反馈。每个客户请求开启一个线程
![博客标签页展开[Hexo]](https://img.wjwj.top/2025/02/18/922b3930b4bda22d8bcfe6c9a4d64727.png)
![博客头像虚化[Hexo]](https://img.wjwj.top/2025/02/15/c8b01a133a448fd52c60c187c8b9e8d0.png)
